๐๏ธGitะฏัะฐ๐๏ธ
Node / meshtastic / Meshtastic-Android / files / core / data / src / commonTest / kotlin / org / meshtastic / core / data / manager / MeshConfigFlowManagerImplTest.kt
Displaying Raw โข Download
core/data/src/commonTest/kotlin/org/meshtastic/core/data/manager/MeshConfigFlowManagerImplTest.kt 3ca87fa0323214c7204c9d37acfe9d4b6ab6ea8b (3ca87fa0) Text, 31.59 KB
T8b949e/*
* Copyright (c) 2026 Meshtastic LLC
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
Tff7b72package T7ee787org.meshtastic.core.data.manager
Tff7b72import T7ee787dev.mokkery.MockMode
Tff7b72import T7ee787dev.mokkery.answering.calls
Tff7b72import T7ee787dev.mokkery.answering.returns
Tff7b72import T7ee787dev.mokkery.every
Tff7b72import T7ee787dev.mokkery.everySuspend
Tff7b72import T7ee787dev.mokkery.matcher.any
Tff7b72import T7ee787dev.mokkery.mock
Tff7b72import T7ee787dev.mokkery.verify
Tff7b72import T7ee787dev.mokkery.verify.VerifyMode
Tff7b72import T7ee787dev.mokkery.verifySuspend
Tff7b72import T7ee787kotlinx.coroutines.ExperimentalCoroutinesApi
Tff7b72import T7ee787kotlinx.coroutines.flow.MutableStateFlow
Tff7b72import T7ee787kotlinx.coroutines.test.StandardTestDispatcher
Tff7b72import T7ee787kotlinx.coroutines.test.TestScope
Tff7b72import T7ee787kotlinx.coroutines.test.advanceTimeBy
Tff7b72import T7ee787kotlinx.coroutines.test.advanceUntilIdle
Tff7b72import T7ee787kotlinx.coroutines.test.runCurrent
Tff7b72import T7ee787kotlinx.coroutines.test.runTest
Tff7b72import T7ee787okio.ByteString.Companion.encodeUtf8
Tff7b72import T7ee787org.meshtastic.core.model.ConnectionState
Tff7b72import T7ee787org.meshtastic.core.repository.CommandSender
Tff7b72import T7ee787org.meshtastic.core.repository.HandshakeConstants
Tff7b72import T7ee787org.meshtastic.core.repository.MeshConnectionManager
Tff7b72import T7ee787org.meshtastic.core.repository.NodeManager
Tff7b72import T7ee787org.meshtastic.core.repository.NodeRepository
Tff7b72import T7ee787org.meshtastic.core.repository.NotificationPrefs
Tff7b72import T7ee787org.meshtastic.core.repository.PacketHandler
Tff7b72import T7ee787org.meshtastic.core.repository.PlatformAnalytics
Tff7b72import T7ee787org.meshtastic.core.repository.RadioConfigRepository
Tff7b72import T7ee787org.meshtastic.core.repository.ServiceRepository
Tff7b72import T7ee787org.meshtastic.proto.DeviceMetadata
Tff7b72import T7ee787org.meshtastic.proto.FileInfo
Tff7b72import T7ee787org.meshtastic.proto.FirmwareEdition
Tff7b72import T7ee787org.meshtastic.proto.HardwareModel
Tff7b72import T7ee787org.meshtastic.proto.NodeInfo
Tff7b72import T7ee787kotlin.test.BeforeTest
Tff7b72import T7ee787kotlin.test.Test
Tff7b72import T7ee787kotlin.test.assertEquals
Tff7b72import T7ee787org.meshtastic.proto.MyNodeInfo Tff7b72as Te6edf3ProtoMyNodeInfo
Tf0883e@OptInTb4b4b4(Te6edf3ExperimentalCoroutinesApiTff7b72::Te6edf3classTb4b4b4)
Tff7b72class T56d364MeshConfigFlowManagerImplTest Tb4b4b4{
Tff7b72private Tff7b72companion Tff7b72object Tb4b4b4{
T8b949e// Production issues two sequential delay(wantConfigDelay) calls (100ms each = 200ms)
T8b949e// plus scheduler slack for the inter-stage heartbeat and startNodeInfoOnly(); bump in
T8b949e// lockstep with wantConfigDelay if it changes.
Tff7b72const Tff7b72val Te6edf3STAGE_TRANSITION_ADVANCE_MS Tff7b72= T79c0ff2T79c0ff5T79c0ff0L
Tb4b4b4}
Tff7b72private Tff7b72val Te6edf3nodeManager Tff7b72= Te6edf3mockTff7b72<Te6edf3NodeManagerTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3connectionManager Tff7b72= Te6edf3mockTff7b72<Te6edf3MeshConnectionManagerTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3nodeRepository Tff7b72= Te6edf3mockTff7b72<Te6edf3NodeRepositoryTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3radioConfigRepository Tff7b72= Te6edf3mockTff7b72<Te6edf3RadioConfigRepositoryTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3serviceRepository Tff7b72= Te6edf3mockTff7b72<Te6edf3ServiceRepositoryTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3analytics Tff7b72= Te6edf3mockTff7b72<Te6edf3PlatformAnalyticsTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3commandSender Tff7b72= Te6edf3mockTff7b72<Te6edf3CommandSenderTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3packetHandler Tff7b72= Te6edf3mockTff7b72<Te6edf3PacketHandlerTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3notificationPrefs Tff7b72= Te6edf3mockTff7b72<Te6edf3NotificationPrefsTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3testDispatcher Tff7b72= Te6edf3StandardTestDispatcherTb4b4b4(Tb4b4b4)
Tff7b72private Tff7b72val Te6edf3testScope Tff7b72= Te6edf3TestScopeTb4b4b4(Te6edf3testDispatcherTb4b4b4)
Tff7b72private Tff7b72lateinit Tff7b72var Te6edf3managerTb4b4b4: Te6edf3MeshConfigFlowManagerImpl
Tff7b72private Tff7b72val Te6edf3myNodeNum Tff7b72= T79c0ff1T79c0ff2T79c0ff3T79c0ff4T79c0ff5
Tff7b72private Tff7b72val Te6edf3protoMyNodeInfo Tff7b72=
Te6edf3ProtoMyNodeInfoTb4b4b4(
Te6edf3my_node_num Tff7b72= Te6edf3myNodeNumTb4b4b4,
Te6edf3min_app_version Tff7b72= T79c0ff3T79c0ff0T79c0ff0T79c0ff0T79c0ff0Tb4b4b4,
Te6edf3device_id Tff7b72= Ta5d6ff"Ta5d6fftest-deviceTa5d6ff"Tb4b4b4.Te6edf3encodeUtf8Tb4b4b4(Tb4b4b4)Tb4b4b4,
Te6edf3pio_env Tff7b72= Ta5d6ff"Ta5d6ff"Tb4b4b4,
Tb4b4b4)
Tff7b72private Tff7b72val Te6edf3metadata Tff7b72=
Te6edf3DeviceMetadataTb4b4b4(Te6edf3firmware_version Tff7b72= Ta5d6ff"Ta5d6ff2.6.0Ta5d6ff"Tb4b4b4, Te6edf3hw_model Tff7b72= Te6edf3HardwareModelTb4b4b4.Te6edf3HELTEC_V3Tb4b4b4, Te6edf3hasWifi Tff7b72= Tff7b72falseTb4b4b4)
Tf0883e@BeforeTest
Tff7b72fun Td2a8ffsetUpTb4b4b4(Tb4b4b4) Tb4b4b4{
Te6edf3every Tb4b4b4{ Te6edf3commandSenderTb4b4b4.Te6edf3getCurrentPacketIdTb4b4b4(Tb4b4b4) Tb4b4b4} Te6edf3returns T79c0ff1T79c0ff0T79c0ff0
Te6edf3every Tb4b4b4{ Te6edf3packetHandlerTb4b4b4.Te6edf3sendToRadioTb4b4b4(Te6edf3anyTff7b72<Te6edf3orgTb4b4b4.Te6edf3meshtasticTb4b4b4.Te6edf3protoTb4b4b4.Te6edf3ToRadioTff7b72>Tb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4} Te6edf3returns Tffa657Unit
Te6edf3every Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3nodeDBbyNodeNum Tb4b4b4} Te6edf3returns Te6edf3emptyMapTb4b4b4(Tb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3myNodeNum Tb4b4b4} Te6edf3returns Te6edf3MutableStateFlowTb4b4b4(Tff7b72nullTb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3notificationPrefsTb4b4b4.Te6edf3nodeEventsAutoDisabledForEvent Tb4b4b4} Te6edf3returns Te6edf3MutableStateFlowTb4b4b4(Tff7b72falseTb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3notificationPrefsTb4b4b4.Te6edf3nodeEventsEnabled Tb4b4b4} Te6edf3returns Te6edf3MutableStateFlowTb4b4b4(Tff7b72trueTb4b4b4)
Te6edf3manager Tff7b72=
Te6edf3MeshConfigFlowManagerImplTb4b4b4(
Te6edf3nodeManager Tff7b72= Te6edf3nodeManagerTb4b4b4,
Te6edf3connectionManager Tff7b72= Te6edf3lazy Tb4b4b4{ Te6edf3connectionManager Tb4b4b4}Tb4b4b4,
Te6edf3nodeRepository Tff7b72= Te6edf3nodeRepositoryTb4b4b4,
Te6edf3radioConfigRepository Tff7b72= Te6edf3radioConfigRepositoryTb4b4b4,
Te6edf3serviceStateWriter Tff7b72= Te6edf3serviceRepositoryTb4b4b4,
Te6edf3analytics Tff7b72= Te6edf3analyticsTb4b4b4,
Te6edf3commandSender Tff7b72= Te6edf3commandSenderTb4b4b4,
Te6edf3heartbeatSender Tff7b72= Te6edf3DataLayerHeartbeatSenderTb4b4b4(Te6edf3packetHandlerTb4b4b4)Tb4b4b4,
Te6edf3notificationPrefs Tff7b72= Te6edf3notificationPrefsTb4b4b4,
Te6edf3scope Tff7b72= Te6edf3testScopeTb4b4b4,
Tb4b4b4)
Tb4b4b4}
T8b949e// ---------- handleMyInfo ----------
Tf0883e@Test
Tff7b72fun Td2a8ff`handleMyInfo transitions to ReceivingConfig and sets myNodeNum`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Te6edf3managerTb4b4b4.Te6edf3handleMyInfoTb4b4b4(Te6edf3protoMyNodeInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3verify Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3setMyNodeNumTb4b4b4(Te6edf3myNodeNumTb4b4b4) Tb4b4b4}
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`handleMyInfo clears persisted radio config`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Te6edf3managerTb4b4b4.Te6edf3handleMyInfoTb4b4b4(Te6edf3protoMyNodeInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3verifySuspend Tb4b4b4{ Te6edf3radioConfigRepositoryTb4b4b4.Te6edf3clearChannelSetTb4b4b4(Tb4b4b4) Tb4b4b4}
Te6edf3verifySuspend Tb4b4b4{ Te6edf3radioConfigRepositoryTb4b4b4.Te6edf3clearLocalConfigTb4b4b4(Tb4b4b4) Tb4b4b4}
Te6edf3verifySuspend Tb4b4b4{ Te6edf3radioConfigRepositoryTb4b4b4.Te6edf3clearLocalModuleConfigTb4b4b4(Tb4b4b4) Tb4b4b4}
Te6edf3verifySuspend Tb4b4b4{ Te6edf3radioConfigRepositoryTb4b4b4.Te6edf3clearDeviceUIConfigTb4b4b4(Tb4b4b4) Tb4b4b4}
Te6edf3verifySuspend Tb4b4b4{ Te6edf3radioConfigRepositoryTb4b4b4.Te6edf3clearFileManifestTb4b4b4(Tb4b4b4) Tb4b4b4}
Tb4b4b4}
T8b949e// ---------- handleLocalMetadata ----------
Tf0883e@Test
Tff7b72fun Td2a8ff`handleLocalMetadata persists metadata when in ReceivingConfig state`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Te6edf3managerTb4b4b4.Te6edf3handleMyInfoTb4b4b4(Te6edf3protoMyNodeInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleLocalMetadataTb4b4b4(Te6edf3metadataTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3verifySuspend Tb4b4b4{ Te6edf3nodeRepositoryTb4b4b4.Te6edf3insertMetadataTb4b4b4(Te6edf3myNodeNumTb4b4b4, Te6edf3metadataTb4b4b4) Tb4b4b4}
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`handleLocalMetadata skips empty metadata`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Te6edf3managerTb4b4b4.Te6edf3handleMyInfoTb4b4b4(Te6edf3protoMyNodeInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
T8b949e// Default/empty DeviceMetadata should not trigger insertMetadata
Te6edf3managerTb4b4b4.Te6edf3handleLocalMetadataTb4b4b4(Te6edf3DeviceMetadataTb4b4b4(Tb4b4b4)Tb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
T8b949e// insertMetadata should only have been called zero times for default metadata
T8b949e// (we just verify no crash occurs)
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`handleLocalMetadata ignored outside ReceivingConfig state`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
T8b949e// State is Idle โ handleLocalMetadata should be a no-op
Te6edf3managerTb4b4b4.Te6edf3handleLocalMetadataTb4b4b4(Te6edf3metadataTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
T8b949e// No crash, no insertMetadata call
Tb4b4b4}
T8b949e// ---------- handleConfigComplete Stage 1 ----------
Tf0883e@Test
Tff7b72fun Td2a8ff`Stage 1 complete builds MyNodeInfo and transitions to ReceivingNodeInfo`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Te6edf3managerTb4b4b4.Te6edf3handleMyInfoTb4b4b4(Te6edf3protoMyNodeInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleLocalMetadataTb4b4b4(Te6edf3metadataTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleConfigCompleteTb4b4b4(Te6edf3HandshakeConstantsTb4b4b4.Te6edf3CONFIG_NONCETb4b4b4)
Te6edf3advanceTimeByTb4b4b4(Te6edf3STAGE_TRANSITION_ADVANCE_MSTb4b4b4)
Te6edf3runCurrentTb4b4b4(Tb4b4b4)
Te6edf3verify Tb4b4b4{ Te6edf3connectionManagerTb4b4b4.Te6edf3onRadioConfigLoadedTb4b4b4(Tb4b4b4) Tb4b4b4}
Te6edf3verify Tb4b4b4{ Te6edf3connectionManagerTb4b4b4.Te6edf3startNodeInfoOnlyTb4b4b4(Tb4b4b4) Tb4b4b4}
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`Stage 1 complete sends heartbeat with non-zero nonce between stages`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3sentPackets Tff7b72= Te6edf3mutableListOfTff7b72<Te6edf3orgTb4b4b4.Te6edf3meshtasticTb4b4b4.Te6edf3protoTb4b4b4.Te6edf3ToRadioTff7b72>Tb4b4b4(Tb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3packetHandlerTb4b4b4.Te6edf3sendToRadioTb4b4b4(Te6edf3anyTff7b72<Te6edf3orgTb4b4b4.Te6edf3meshtasticTb4b4b4.Te6edf3protoTb4b4b4.Te6edf3ToRadioTff7b72>Tb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4} Te6edf3calls
Tb4b4b4{ Te6edf3call Tff7b72-Tff7b72>
Te6edf3sentPacketsTb4b4b4.Te6edf3addTb4b4b4(Te6edf3callTb4b4b4.Te6edf3argTb4b4b4(T79c0ff0Tb4b4b4)Tb4b4b4)
Tb4b4b4}
Te6edf3managerTb4b4b4.Te6edf3handleMyInfoTb4b4b4(Te6edf3protoMyNodeInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleLocalMetadataTb4b4b4(Te6edf3metadataTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3sentPacketsTb4b4b4.Te6edf3clearTb4b4b4(Tb4b4b4) T8b949e// Clear any packets from prior phases
Te6edf3managerTb4b4b4.Te6edf3handleConfigCompleteTb4b4b4(Te6edf3HandshakeConstantsTb4b4b4.Te6edf3CONFIG_NONCETb4b4b4)
Te6edf3advanceTimeByTb4b4b4(Te6edf3STAGE_TRANSITION_ADVANCE_MSTb4b4b4)
Te6edf3runCurrentTb4b4b4(Tb4b4b4)
Tff7b72val Te6edf3heartbeats Tff7b72= Te6edf3sentPacketsTb4b4b4.Te6edf3filter Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3heartbeat Tff7b72!Tff7b72= Tff7b72null Tb4b4b4}
Te6edf3assertEqualsTb4b4b4(T79c0ff1Tb4b4b4, Te6edf3heartbeatsTb4b4b4.Te6edf3sizeTb4b4b4, Ta5d6ff"Ta5d6ffExpected exactly one inter-stage heartbeatTa5d6ff"Tb4b4b4)
Te6edf3assertEqualsTb4b4b4(
Tff7b72trueTb4b4b4,
Te6edf3heartbeatsTff7b72[T79c0ff0Tff7b72]Tb4b4b4.Te6edf3heartbeatTff7b72!!Tb4b4b4.Te6edf3nonce Tff7b72!Tff7b72= T79c0ff0Tb4b4b4,
Ta5d6ff"Ta5d6ffInter-stage heartbeat should have a non-zero nonceTa5d6ff"Tb4b4b4,
Tb4b4b4)
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`Stage 1 complete with old firmware logs warning but continues handshake`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3oldMetadata Tff7b72=
Te6edf3DeviceMetadataTb4b4b4(Te6edf3firmware_version Tff7b72= Ta5d6ff"Ta5d6ff2.3.0Ta5d6ff"Tb4b4b4, Te6edf3hw_model Tff7b72= Te6edf3HardwareModelTb4b4b4.Te6edf3HELTEC_V3Tb4b4b4, Te6edf3hasWifi Tff7b72= Tff7b72falseTb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleMyInfoTb4b4b4(Te6edf3protoMyNodeInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleLocalMetadataTb4b4b4(Te6edf3oldMetadataTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleConfigCompleteTb4b4b4(Te6edf3HandshakeConstantsTb4b4b4.Te6edf3CONFIG_NONCETb4b4b4)
Te6edf3advanceTimeByTb4b4b4(Te6edf3STAGE_TRANSITION_ADVANCE_MSTb4b4b4)
Te6edf3runCurrentTb4b4b4(Tb4b4b4)
T8b949e// Handshake should still progress despite old firmware
Te6edf3verify Tb4b4b4{ Te6edf3connectionManagerTb4b4b4.Te6edf3onRadioConfigLoadedTb4b4b4(Tb4b4b4) Tb4b4b4}
Te6edf3verify Tb4b4b4{ Te6edf3connectionManagerTb4b4b4.Te6edf3startNodeInfoOnlyTb4b4b4(Tb4b4b4) Tb4b4b4}
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`Stage 1 complete without metadata still succeeds with null firmware version`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Te6edf3managerTb4b4b4.Te6edf3handleMyInfoTb4b4b4(Te6edf3protoMyNodeInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
T8b949e// No metadata provided
Te6edf3managerTb4b4b4.Te6edf3handleConfigCompleteTb4b4b4(Te6edf3HandshakeConstantsTb4b4b4.Te6edf3CONFIG_NONCETb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3verify Tb4b4b4{ Te6edf3connectionManagerTb4b4b4.Te6edf3onRadioConfigLoadedTb4b4b4(Tb4b4b4) Tb4b4b4}
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`Stage 1 complete updates progress for node list loading`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Te6edf3managerTb4b4b4.Te6edf3handleMyInfoTb4b4b4(Te6edf3protoMyNodeInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleLocalMetadataTb4b4b4(Te6edf3metadataTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleConfigCompleteTb4b4b4(Te6edf3HandshakeConstantsTb4b4b4.Te6edf3CONFIG_NONCETb4b4b4)
Te6edf3advanceTimeByTb4b4b4(Te6edf3STAGE_TRANSITION_ADVANCE_MSTb4b4b4)
Te6edf3runCurrentTb4b4b4(Tb4b4b4)
Te6edf3verify Tb4b4b4{ Te6edf3serviceRepositoryTb4b4b4.Te6edf3setConnectionProgressTb4b4b4(Ta5d6ff"Ta5d6ffLoading node listTa5d6ff"Tb4b4b4) Tb4b4b4}
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`Stage 1 complete id ignored when not in ReceivingConfig state`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
T8b949e// State is Idle โ should be a no-op
Te6edf3managerTb4b4b4.Te6edf3handleConfigCompleteTb4b4b4(Te6edf3HandshakeConstantsTb4b4b4.Te6edf3CONFIG_NONCETb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
T8b949e// No crash, no onRadioConfigLoaded
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`Duplicate Stage 1 config_complete does not re-trigger`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Te6edf3managerTb4b4b4.Te6edf3handleMyInfoTb4b4b4(Te6edf3protoMyNodeInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleLocalMetadataTb4b4b4(Te6edf3metadataTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleConfigCompleteTb4b4b4(Te6edf3HandshakeConstantsTb4b4b4.Te6edf3CONFIG_NONCETb4b4b4)
Te6edf3advanceTimeByTb4b4b4(Te6edf3STAGE_TRANSITION_ADVANCE_MSTb4b4b4)
Te6edf3runCurrentTb4b4b4(Tb4b4b4)
T8b949e// Now in ReceivingNodeInfo โ a second Stage 1 complete should be ignored
Te6edf3managerTb4b4b4.Te6edf3handleConfigCompleteTb4b4b4(Te6edf3HandshakeConstantsTb4b4b4.Te6edf3CONFIG_NONCETb4b4b4)
Te6edf3advanceTimeByTb4b4b4(Te6edf3STAGE_TRANSITION_ADVANCE_MSTb4b4b4)
Te6edf3runCurrentTb4b4b4(Tb4b4b4)
Tb4b4b4}
T8b949e// ---------- handleNodeInfo ----------
Tf0883e@Test
Tff7b72fun Td2a8ff`handleNodeInfo accumulates nodes during Stage 2`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
T8b949e// Transition to Stage 2
Te6edf3managerTb4b4b4.Te6edf3handleMyInfoTb4b4b4(Te6edf3protoMyNodeInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleLocalMetadataTb4b4b4(Te6edf3metadataTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleConfigCompleteTb4b4b4(Te6edf3HandshakeConstantsTb4b4b4.Te6edf3CONFIG_NONCETb4b4b4)
Te6edf3advanceTimeByTb4b4b4(Te6edf3STAGE_TRANSITION_ADVANCE_MSTb4b4b4)
Te6edf3runCurrentTb4b4b4(Tb4b4b4)
T8b949e// Now in ReceivingNodeInfo
Te6edf3managerTb4b4b4.Te6edf3handleNodeInfoTb4b4b4(Te6edf3NodeInfoTb4b4b4(Te6edf3num Tff7b72= T79c0ff1T79c0ff0T79c0ff0Tb4b4b4)Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleNodeInfoTb4b4b4(Te6edf3NodeInfoTb4b4b4(Te6edf3num Tff7b72= T79c0ff2T79c0ff0T79c0ff0Tb4b4b4)Tb4b4b4)
Te6edf3assertEqualsTb4b4b4(T79c0ff2Tb4b4b4, Te6edf3managerTb4b4b4.Te6edf3newNodeCountTb4b4b4)
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`handleNodeInfo buffers nodes received during Stage 1`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3testNode Tff7b72= Te6edf3orgTb4b4b4.Te6edf3meshtasticTb4b4b4.Te6edf3coreTb4b4b4.Te6edf3testingTb4b4b4.Te6edf3TestDataFactoryTb4b4b4.Te6edf3createTestNodeTb4b4b4(Te6edf3num Tff7b72= T79c0ff1T79c0ff0T79c0ff0Tb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3nodeDBbyNodeNum Tb4b4b4} Te6edf3returns Te6edf3mapOfTb4b4b4(T79c0ff1T79c0ff0T79c0ff0 Te6edf3to Te6edf3testNodeTb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleMyInfoTb4b4b4(Te6edf3protoMyNodeInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleNodeInfoTb4b4b4(Te6edf3NodeInfoTb4b4b4(Te6edf3num Tff7b72= T79c0ff1T79c0ff0T79c0ff0Tb4b4b4)Tb4b4b4)
Te6edf3assertEqualsTb4b4b4(T79c0ff1Tb4b4b4, Te6edf3managerTb4b4b4.Te6edf3newNodeCountTb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleLocalMetadataTb4b4b4(Te6edf3metadataTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleConfigCompleteTb4b4b4(Te6edf3HandshakeConstantsTb4b4b4.Te6edf3CONFIG_NONCETb4b4b4)
Te6edf3advanceTimeByTb4b4b4(Te6edf3STAGE_TRANSITION_ADVANCE_MSTb4b4b4)
Te6edf3runCurrentTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleConfigCompleteTb4b4b4(Te6edf3HandshakeConstantsTb4b4b4.Te6edf3NODE_INFO_NONCETb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3verify Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3installNodeInfoTb4b4b4(Te6edf3NodeInfoTb4b4b4(Te6edf3num Tff7b72= T79c0ff1T79c0ff0T79c0ff0Tb4b4b4)Tb4b4b4) Tb4b4b4}
Te6edf3verifySuspend Tb4b4b4{ Te6edf3connectionManagerTb4b4b4.Te6edf3onNodeDbReadyTb4b4b4(Tb4b4b4) Tb4b4b4}
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`handleNodeInfo ignored outside Stage 2`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
T8b949e// State is Idle
Te6edf3managerTb4b4b4.Te6edf3handleNodeInfoTb4b4b4(Te6edf3NodeInfoTb4b4b4(Te6edf3num Tff7b72= T79c0ff9T79c0ff9T79c0ff9Tb4b4b4)Tb4b4b4)
Te6edf3assertEqualsTb4b4b4(T79c0ff0Tb4b4b4, Te6edf3managerTb4b4b4.Te6edf3newNodeCountTb4b4b4)
Tb4b4b4}
T8b949e// ---------- handleConfigComplete Stage 2 ----------
Tf0883e@Test
Tff7b72fun Td2a8ff`Stage 2 complete processes nodes and sets Connected state`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3testNode Tff7b72= Te6edf3orgTb4b4b4.Te6edf3meshtasticTb4b4b4.Te6edf3coreTb4b4b4.Te6edf3testingTb4b4b4.Te6edf3TestDataFactoryTb4b4b4.Te6edf3createTestNodeTb4b4b4(Te6edf3num Tff7b72= T79c0ff1T79c0ff0T79c0ff0Tb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3nodeDBbyNodeNum Tb4b4b4} Te6edf3returns Te6edf3mapOfTb4b4b4(T79c0ff1T79c0ff0T79c0ff0 Te6edf3to Te6edf3testNodeTb4b4b4)
T8b949e// Full handshake: MyInfo -> metadata -> Stage 1 complete -> nodes -> Stage 2 complete
Te6edf3managerTb4b4b4.Te6edf3handleMyInfoTb4b4b4(Te6edf3protoMyNodeInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleLocalMetadataTb4b4b4(Te6edf3metadataTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleConfigCompleteTb4b4b4(Te6edf3HandshakeConstantsTb4b4b4.Te6edf3CONFIG_NONCETb4b4b4)
Te6edf3advanceTimeByTb4b4b4(Te6edf3STAGE_TRANSITION_ADVANCE_MSTb4b4b4)
Te6edf3runCurrentTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleNodeInfoTb4b4b4(Te6edf3NodeInfoTb4b4b4(Te6edf3num Tff7b72= T79c0ff1T79c0ff0T79c0ff0Tb4b4b4)Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleConfigCompleteTb4b4b4(Te6edf3HandshakeConstantsTb4b4b4.Te6edf3NODE_INFO_NONCETb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3verify Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3installNodeInfoTb4b4b4(Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}
Te6edf3verify Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3setNodeDbReadyTb4b4b4(Tff7b72trueTb4b4b4) Tb4b4b4}
Te6edf3verify Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3setAllowNodeDbWritesTb4b4b4(Tff7b72trueTb4b4b4) Tb4b4b4}
Te6edf3verifySuspend Tb4b4b4{ Te6edf3connectionManagerTb4b4b4.Te6edf3onNodeDbReadyTb4b4b4(Tb4b4b4) Tb4b4b4}
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`Stage 2 complete id ignored when not in ReceivingNodeInfo state`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Te6edf3managerTb4b4b4.Te6edf3handleConfigCompleteTb4b4b4(Te6edf3HandshakeConstantsTb4b4b4.Te6edf3NODE_INFO_NONCETb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
T8b949e// No crash
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`Stage 2 complete with no nodes still transitions to Connected`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Te6edf3managerTb4b4b4.Te6edf3handleMyInfoTb4b4b4(Te6edf3protoMyNodeInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleLocalMetadataTb4b4b4(Te6edf3metadataTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleConfigCompleteTb4b4b4(Te6edf3HandshakeConstantsTb4b4b4.Te6edf3CONFIG_NONCETb4b4b4)
Te6edf3advanceTimeByTb4b4b4(Te6edf3STAGE_TRANSITION_ADVANCE_MSTb4b4b4)
Te6edf3runCurrentTb4b4b4(Tb4b4b4)
T8b949e// No handleNodeInfo calls โ empty node list
Te6edf3managerTb4b4b4.Te6edf3handleConfigCompleteTb4b4b4(Te6edf3HandshakeConstantsTb4b4b4.Te6edf3NODE_INFO_NONCETb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3verify Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3setNodeDbReadyTb4b4b4(Tff7b72trueTb4b4b4) Tb4b4b4}
Te6edf3verifySuspend Tb4b4b4{ Te6edf3connectionManagerTb4b4b4.Te6edf3onNodeDbReadyTb4b4b4(Tb4b4b4) Tb4b4b4}
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`Stage 2 complete keeps connected when post NodeDB side effects fail`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Te6edf3every Tb4b4b4{ Te6edf3analyticsTb4b4b4.Te6edf3setDeviceAttributesTb4b4b4(Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4} Te6edf3calls Tb4b4b4{ Tff7b72throw Te6edf3IllegalStateExceptionTb4b4b4(Ta5d6ff"Ta5d6ffanalyticsTa5d6ff"Tb4b4b4) Tb4b4b4}
Te6edf3everySuspend Tb4b4b4{ Te6edf3connectionManagerTb4b4b4.Te6edf3onNodeDbReadyTb4b4b4(Tb4b4b4) Tb4b4b4} Te6edf3calls Tb4b4b4{ Tff7b72throw Te6edf3IllegalStateExceptionTb4b4b4(Ta5d6ff"Ta5d6ffside effectsTa5d6ff"Tb4b4b4) Tb4b4b4}
Te6edf3managerTb4b4b4.Te6edf3handleMyInfoTb4b4b4(Te6edf3protoMyNodeInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleLocalMetadataTb4b4b4(Te6edf3metadataTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleConfigCompleteTb4b4b4(Te6edf3HandshakeConstantsTb4b4b4.Te6edf3CONFIG_NONCETb4b4b4)
Te6edf3advanceTimeByTb4b4b4(Te6edf3STAGE_TRANSITION_ADVANCE_MSTb4b4b4)
Te6edf3runCurrentTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleConfigCompleteTb4b4b4(Te6edf3HandshakeConstantsTb4b4b4.Te6edf3NODE_INFO_NONCETb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3verify Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3setNodeDbReadyTb4b4b4(Tff7b72trueTb4b4b4) Tb4b4b4}
Te6edf3verify Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3setAllowNodeDbWritesTb4b4b4(Tff7b72trueTb4b4b4) Tb4b4b4}
Te6edf3verify Tb4b4b4{ Te6edf3serviceRepositoryTb4b4b4.Te6edf3setConnectionStateTb4b4b4(Te6edf3ConnectionStateTb4b4b4.Te6edf3ConnectedTb4b4b4) Tb4b4b4}
Te6edf3verifySuspend Tb4b4b4{ Te6edf3connectionManagerTb4b4b4.Te6edf3onNodeDbReadyTb4b4b4(Tb4b4b4) Tb4b4b4}
Te6edf3verifyTb4b4b4(Te6edf3mode Tff7b72= Te6edf3VerifyModeTb4b4b4.Te6edf3notTb4b4b4) Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3setNodeDbReadyTb4b4b4(Tff7b72falseTb4b4b4) Tb4b4b4}
Te6edf3verifyTb4b4b4(Te6edf3mode Tff7b72= Te6edf3VerifyModeTb4b4b4.Te6edf3notTb4b4b4) Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3setAllowNodeDbWritesTb4b4b4(Tff7b72falseTb4b4b4) Tb4b4b4}
Te6edf3verifyTb4b4b4(Te6edf3mode Tff7b72= Te6edf3VerifyModeTb4b4b4.Te6edf3notTb4b4b4) Tb4b4b4{ Te6edf3connectionManagerTb4b4b4.Te6edf3recoverPostHandshakeFailureTb4b4b4(Tb4b4b4) Tb4b4b4}
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`Stage 2 complete disconnects when NodeDB install fails`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Te6edf3everySuspend Tb4b4b4{ Te6edf3nodeRepositoryTb4b4b4.Te6edf3installConfigTb4b4b4(Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4} Te6edf3calls Tb4b4b4{ Tff7b72throw Te6edf3IllegalStateExceptionTb4b4b4(Ta5d6ff"Ta5d6ffroomTa5d6ff"Tb4b4b4) Tb4b4b4}
Te6edf3managerTb4b4b4.Te6edf3handleMyInfoTb4b4b4(Te6edf3protoMyNodeInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleLocalMetadataTb4b4b4(Te6edf3metadataTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleConfigCompleteTb4b4b4(Te6edf3HandshakeConstantsTb4b4b4.Te6edf3CONFIG_NONCETb4b4b4)
Te6edf3advanceTimeByTb4b4b4(Te6edf3STAGE_TRANSITION_ADVANCE_MSTb4b4b4)
Te6edf3runCurrentTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleConfigCompleteTb4b4b4(Te6edf3HandshakeConstantsTb4b4b4.Te6edf3NODE_INFO_NONCETb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3verify Tb4b4b4{ Te6edf3connectionManagerTb4b4b4.Te6edf3onHandshakeCompleteTb4b4b4(Tb4b4b4) Tb4b4b4}
Te6edf3verify Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3setNodeDbReadyTb4b4b4(Tff7b72falseTb4b4b4) Tb4b4b4}
Te6edf3verify Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3setAllowNodeDbWritesTb4b4b4(Tff7b72falseTb4b4b4) Tb4b4b4}
Te6edf3verify Tb4b4b4{ Te6edf3connectionManagerTb4b4b4.Te6edf3recoverPostHandshakeFailureTb4b4b4(Tb4b4b4) Tb4b4b4}
Te6edf3verifyTb4b4b4(Te6edf3mode Tff7b72= Te6edf3VerifyModeTb4b4b4.Te6edf3notTb4b4b4) Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3setNodeDbReadyTb4b4b4(Tff7b72trueTb4b4b4) Tb4b4b4}
Te6edf3verifySuspendTb4b4b4(Te6edf3mode Tff7b72= Te6edf3VerifyModeTb4b4b4.Te6edf3notTb4b4b4) Tb4b4b4{ Te6edf3connectionManagerTb4b4b4.Te6edf3onNodeDbReadyTb4b4b4(Tb4b4b4) Tb4b4b4}
Tb4b4b4}
T8b949e// ---------- Unknown config_complete_id ----------
Tf0883e@Test
Tff7b72fun Td2a8ff`Unknown config_complete_id is ignored`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Te6edf3managerTb4b4b4.Te6edf3handleConfigCompleteTb4b4b4(T79c0ff9T79c0ff9T79c0ff9T79c0ff9T79c0ff9Tb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
T8b949e// No crash
Tb4b4b4}
T8b949e// ---------- newNodeCount ----------
Tf0883e@Test
Tff7b72fun Td2a8ff`newNodeCount returns 0 when not in ReceivingNodeInfo state`Tb4b4b4(Tb4b4b4) Tb4b4b4{
Te6edf3assertEqualsTb4b4b4(T79c0ff0Tb4b4b4, Te6edf3managerTb4b4b4.Te6edf3newNodeCountTb4b4b4)
Tb4b4b4}
T8b949e// ---------- handleFileInfo ----------
Tf0883e@Test
Tff7b72fun Td2a8ff`handleFileInfo delegates to radioConfigRepository`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3fileInfo Tff7b72= Te6edf3FileInfoTb4b4b4(Te6edf3file_name Tff7b72= Ta5d6ff"Ta5d6fffirmware.binTa5d6ff"Tb4b4b4, Te6edf3size_bytes Tff7b72= T79c0ff1T79c0ff0T79c0ff2T79c0ff4Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleFileInfoTb4b4b4(Te6edf3fileInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3verifySuspend Tb4b4b4{ Te6edf3radioConfigRepositoryTb4b4b4.Te6edf3addFileInfoTb4b4b4(Te6edf3fileInfoTb4b4b4) Tb4b4b4}
Tb4b4b4}
T8b949e// ---------- triggerWantConfig ----------
Tf0883e@Test
Tff7b72fun Td2a8ff`triggerWantConfig delegates to connectionManager startConfigOnly`Tb4b4b4(Tb4b4b4) Tb4b4b4{
Te6edf3managerTb4b4b4.Te6edf3triggerWantConfigTb4b4b4(Tb4b4b4)
Te6edf3verify Tb4b4b4{ Te6edf3connectionManagerTb4b4b4.Te6edf3startConfigOnlyTb4b4b4(Tb4b4b4) Tb4b4b4}
Tb4b4b4}
T8b949e// ---------- Full handshake flow ----------
Tf0883e@Test
Tff7b72fun Td2a8ff`Full handshake from Idle to Complete`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3testNode Tff7b72= Te6edf3orgTb4b4b4.Te6edf3meshtasticTb4b4b4.Te6edf3coreTb4b4b4.Te6edf3testingTb4b4b4.Te6edf3TestDataFactoryTb4b4b4.Te6edf3createTestNodeTb4b4b4(Te6edf3num Tff7b72= T79c0ff1T79c0ff0T79c0ff0Tb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3nodeDBbyNodeNum Tb4b4b4} Te6edf3returns Te6edf3mapOfTb4b4b4(T79c0ff1T79c0ff0T79c0ff0 Te6edf3to Te6edf3testNodeTb4b4b4)
T8b949e// Stage 0: Idle -> handleMyInfo
Te6edf3managerTb4b4b4.Te6edf3handleMyInfoTb4b4b4(Te6edf3protoMyNodeInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3verify Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3setMyNodeNumTb4b4b4(Te6edf3myNodeNumTb4b4b4) Tb4b4b4}
T8b949e// Receive metadata during Stage 1
Te6edf3managerTb4b4b4.Te6edf3handleLocalMetadataTb4b4b4(Te6edf3metadataTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
T8b949e// Stage 1 complete
Te6edf3managerTb4b4b4.Te6edf3handleConfigCompleteTb4b4b4(Te6edf3HandshakeConstantsTb4b4b4.Te6edf3CONFIG_NONCETb4b4b4)
Te6edf3advanceTimeByTb4b4b4(Te6edf3STAGE_TRANSITION_ADVANCE_MSTb4b4b4)
Te6edf3runCurrentTb4b4b4(Tb4b4b4)
Te6edf3verify Tb4b4b4{ Te6edf3connectionManagerTb4b4b4.Te6edf3onRadioConfigLoadedTb4b4b4(Tb4b4b4) Tb4b4b4}
T8b949e// Receive NodeInfo during Stage 2
Te6edf3managerTb4b4b4.Te6edf3handleNodeInfoTb4b4b4(Te6edf3NodeInfoTb4b4b4(Te6edf3num Tff7b72= T79c0ff1T79c0ff0T79c0ff0Tb4b4b4)Tb4b4b4)
Te6edf3assertEqualsTb4b4b4(T79c0ff1Tb4b4b4, Te6edf3managerTb4b4b4.Te6edf3newNodeCountTb4b4b4)
T8b949e// Stage 2 complete
Te6edf3managerTb4b4b4.Te6edf3handleConfigCompleteTb4b4b4(Te6edf3HandshakeConstantsTb4b4b4.Te6edf3NODE_INFO_NONCETb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3verify Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3setNodeDbReadyTb4b4b4(Tff7b72trueTb4b4b4) Tb4b4b4}
Te6edf3verifySuspend Tb4b4b4{ Te6edf3connectionManagerTb4b4b4.Te6edf3onNodeDbReadyTb4b4b4(Tb4b4b4) Tb4b4b4}
T8b949e// After complete, newNodeCount should be 0 (state is Complete)
Te6edf3assertEqualsTb4b4b4(T79c0ff0Tb4b4b4, Te6edf3managerTb4b4b4.Te6edf3newNodeCountTb4b4b4)
Tb4b4b4}
T8b949e// ---------- Interrupted handshake ----------
Tf0883e@Test
Tff7b72fun Td2a8ff`handleMyInfo resets stale handshake state`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
T8b949e// Start first handshake
Te6edf3managerTb4b4b4.Te6edf3handleMyInfoTb4b4b4(Te6edf3protoMyNodeInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleLocalMetadataTb4b4b4(Te6edf3metadataTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
T8b949e// Before Stage 1 completes, a new handleMyInfo arrives (device rebooted)
Tff7b72val Te6edf3newMyInfo Tff7b72= Te6edf3protoMyNodeInfoTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3my_node_num Tff7b72= T79c0ff9T79c0ff9T79c0ff9T79c0ff9T79c0ff9Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleMyInfoTb4b4b4(Te6edf3newMyInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3verify Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3setMyNodeNumTb4b4b4(T79c0ff9T79c0ff9T79c0ff9T79c0ff9T79c0ff9Tb4b4b4) Tb4b4b4}
Tb4b4b4}
T8b949e// ---------- Event firmware notification defaults ----------
Tf0883e@Test
Tff7b72fun Td2a8ff`handleMyInfo disables node notifications for event firmware`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Te6edf3every Tb4b4b4{ Te6edf3notificationPrefsTb4b4b4.Te6edf3nodeEventsAutoDisabledForEvent Tb4b4b4} Te6edf3returns Te6edf3MutableStateFlowTb4b4b4(Tff7b72falseTb4b4b4)
Tff7b72val Te6edf3eventMyInfo Tff7b72= Te6edf3protoMyNodeInfoTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3firmware_edition Tff7b72= Te6edf3FirmwareEditionTb4b4b4.Te6edf3DEFCONTb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleMyInfoTb4b4b4(Te6edf3eventMyInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3verify Tb4b4b4{ Te6edf3notificationPrefsTb4b4b4.Te6edf3setNodeEventsEnabledTb4b4b4(Tff7b72falseTb4b4b4) Tb4b4b4}
Te6edf3verify Tb4b4b4{ Te6edf3notificationPrefsTb4b4b4.Te6edf3setNodeEventsAutoDisabledForEventTb4b4b4(Tff7b72trueTb4b4b4) Tb4b4b4}
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`handleMyInfo does not re-disable if already auto-disabled`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Te6edf3every Tb4b4b4{ Te6edf3notificationPrefsTb4b4b4.Te6edf3nodeEventsAutoDisabledForEvent Tb4b4b4} Te6edf3returns Te6edf3MutableStateFlowTb4b4b4(Tff7b72trueTb4b4b4)
Tff7b72val Te6edf3eventMyInfo Tff7b72= Te6edf3protoMyNodeInfoTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3firmware_edition Tff7b72= Te6edf3FirmwareEditionTb4b4b4.Te6edf3DEFCONTb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleMyInfoTb4b4b4(Te6edf3eventMyInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3verifyTb4b4b4(Te6edf3mode Tff7b72= Te6edf3VerifyModeTb4b4b4.Te6edf3notTb4b4b4) Tb4b4b4{ Te6edf3notificationPrefsTb4b4b4.Te6edf3setNodeEventsEnabledTb4b4b4(Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`handleMyInfo re-enables node notifications when vanilla firmware reconnects`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Te6edf3every Tb4b4b4{ Te6edf3notificationPrefsTb4b4b4.Te6edf3nodeEventsAutoDisabledForEvent Tb4b4b4} Te6edf3returns Te6edf3MutableStateFlowTb4b4b4(Tff7b72trueTb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleMyInfoTb4b4b4(Te6edf3protoMyNodeInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3verify Tb4b4b4{ Te6edf3notificationPrefsTb4b4b4.Te6edf3setNodeEventsEnabledTb4b4b4(Tff7b72trueTb4b4b4) Tb4b4b4}
Te6edf3verify Tb4b4b4{ Te6edf3notificationPrefsTb4b4b4.Te6edf3setNodeEventsAutoDisabledForEventTb4b4b4(Tff7b72falseTb4b4b4) Tb4b4b4}
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`handleMyInfo does not touch prefs for vanilla when not previously auto-disabled`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Te6edf3every Tb4b4b4{ Te6edf3notificationPrefsTb4b4b4.Te6edf3nodeEventsAutoDisabledForEvent Tb4b4b4} Te6edf3returns Te6edf3MutableStateFlowTb4b4b4(Tff7b72falseTb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleMyInfoTb4b4b4(Te6edf3protoMyNodeInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3verifyTb4b4b4(Te6edf3mode Tff7b72= Te6edf3VerifyModeTb4b4b4.Te6edf3notTb4b4b4) Tb4b4b4{ Te6edf3notificationPrefsTb4b4b4.Te6edf3setNodeEventsEnabledTb4b4b4(Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}
Te6edf3verifyTb4b4b4(Te6edf3mode Tff7b72= Te6edf3VerifyModeTb4b4b4.Te6edf3notTb4b4b4) Tb4b4b4{ Te6edf3notificationPrefsTb4b4b4.Te6edf3setNodeEventsAutoDisabledForEventTb4b4b4(Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}
Tb4b4b4}
T8b949e// ---------- onHandshakeProgress ----------
Tf0883e@Test
Tff7b72fun Td2a8ff`handleMyInfo calls onHandshakeProgress`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Te6edf3managerTb4b4b4.Te6edf3handleMyInfoTb4b4b4(Te6edf3protoMyNodeInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3verify Tb4b4b4{ Te6edf3connectionManagerTb4b4b4.Te6edf3onHandshakeProgressTb4b4b4(Tb4b4b4) Tb4b4b4}
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`handleLocalMetadata in ReceivingConfig calls onHandshakeProgress`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Te6edf3managerTb4b4b4.Te6edf3handleMyInfoTb4b4b4(Te6edf3protoMyNodeInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleLocalMetadataTb4b4b4(Te6edf3metadataTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
T8b949e// handleMyInfo fires one call; handleLocalMetadata adds exactly one more in ReceivingConfig.
Te6edf3verifyTb4b4b4(Te6edf3mode Tff7b72= Te6edf3VerifyModeTb4b4b4.Te6edf3exactlyTb4b4b4(T79c0ff2Tb4b4b4)Tb4b4b4) Tb4b4b4{ Te6edf3connectionManagerTb4b4b4.Te6edf3onHandshakeProgressTb4b4b4(Tb4b4b4) Tb4b4b4}
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`handleLocalMetadata outside ReceivingConfig does not call onHandshakeProgress`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
T8b949e// State is Idle โ metadata is ignored and must not reset the watchdog.
Te6edf3managerTb4b4b4.Te6edf3handleLocalMetadataTb4b4b4(Te6edf3metadataTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3verifyTb4b4b4(Te6edf3mode Tff7b72= Te6edf3VerifyModeTb4b4b4.Te6edf3notTb4b4b4) Tb4b4b4{ Te6edf3connectionManagerTb4b4b4.Te6edf3onHandshakeProgressTb4b4b4(Tb4b4b4) Tb4b4b4}
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`handleFileInfo calls onHandshakeProgress`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3fileInfo Tff7b72= Te6edf3FileInfoTb4b4b4(Te6edf3file_name Tff7b72= Ta5d6ff"Ta5d6fffirmware.binTa5d6ff"Tb4b4b4, Te6edf3size_bytes Tff7b72= T79c0ff1T79c0ff0T79c0ff2T79c0ff4Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleFileInfoTb4b4b4(Te6edf3fileInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3verify Tb4b4b4{ Te6edf3connectionManagerTb4b4b4.Te6edf3onHandshakeProgressTb4b4b4(Tb4b4b4) Tb4b4b4}
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`handleNodeInfo during Stage 1 calls onHandshakeProgress`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Te6edf3managerTb4b4b4.Te6edf3handleMyInfoTb4b4b4(Te6edf3protoMyNodeInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleNodeInfoTb4b4b4(Te6edf3NodeInfoTb4b4b4(Te6edf3num Tff7b72= T79c0ff1T79c0ff0T79c0ff0Tb4b4b4)Tb4b4b4)
T8b949e// handleMyInfo fires one call; handleNodeInfo in ReceivingConfig adds exactly one more.
Te6edf3verifyTb4b4b4(Te6edf3mode Tff7b72= Te6edf3VerifyModeTb4b4b4.Te6edf3exactlyTb4b4b4(T79c0ff2Tb4b4b4)Tb4b4b4) Tb4b4b4{ Te6edf3connectionManagerTb4b4b4.Te6edf3onHandshakeProgressTb4b4b4(Tb4b4b4) Tb4b4b4}
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`handleNodeInfo during Stage 2 calls onHandshakeProgress`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Te6edf3managerTb4b4b4.Te6edf3handleMyInfoTb4b4b4(Te6edf3protoMyNodeInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleLocalMetadataTb4b4b4(Te6edf3metadataTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleConfigCompleteTb4b4b4(Te6edf3HandshakeConstantsTb4b4b4.Te6edf3CONFIG_NONCETb4b4b4)
Te6edf3advanceTimeByTb4b4b4(Te6edf3STAGE_TRANSITION_ADVANCE_MSTb4b4b4)
Te6edf3runCurrentTb4b4b4(Tb4b4b4)
T8b949e// Now in ReceivingNodeInfo โ a NodeInfo packet must reset the watchdog.
Te6edf3managerTb4b4b4.Te6edf3handleNodeInfoTb4b4b4(Te6edf3NodeInfoTb4b4b4(Te6edf3num Tff7b72= T79c0ff1T79c0ff0T79c0ff0Tb4b4b4)Tb4b4b4)
T8b949e// Prior calls: handleMyInfo(1) + handleLocalMetadata(1) + handleConfigOnlyComplete(1) = 3.
T8b949e// handleNodeInfo adds exactly one more.
Te6edf3verifyTb4b4b4(Te6edf3mode Tff7b72= Te6edf3VerifyModeTb4b4b4.Te6edf3exactlyTb4b4b4(T79c0ff4Tb4b4b4)Tb4b4b4) Tb4b4b4{ Te6edf3connectionManagerTb4b4b4.Te6edf3onHandshakeProgressTb4b4b4(Tb4b4b4) Tb4b4b4}
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`Stage 1 complete calls onHandshakeProgress`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Te6edf3managerTb4b4b4.Te6edf3handleMyInfoTb4b4b4(Te6edf3protoMyNodeInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleLocalMetadataTb4b4b4(Te6edf3metadataTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleConfigCompleteTb4b4b4(Te6edf3HandshakeConstantsTb4b4b4.Te6edf3CONFIG_NONCETb4b4b4)
Te6edf3advanceTimeByTb4b4b4(Te6edf3STAGE_TRANSITION_ADVANCE_MSTb4b4b4)
Te6edf3runCurrentTb4b4b4(Tb4b4b4)
T8b949e// handleMyInfo(1) + handleLocalMetadata(1) + handleConfigOnlyComplete(1) = 3.
Te6edf3verifyTb4b4b4(Te6edf3mode Tff7b72= Te6edf3VerifyModeTb4b4b4.Te6edf3exactlyTb4b4b4(T79c0ff3Tb4b4b4)Tb4b4b4) Tb4b4b4{ Te6edf3connectionManagerTb4b4b4.Te6edf3onHandshakeProgressTb4b4b4(Tb4b4b4) Tb4b4b4}
Tb4b4b4}
Tf0883e@Test
Tff7b72fun Td2a8ff`handleNodeInfo outside active handshake does not call onHandshakeProgress`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
T8b949e// State is Idle โ NodeInfo is ignored and must not reset the watchdog.
Te6edf3managerTb4b4b4.Te6edf3handleNodeInfoTb4b4b4(Te6edf3NodeInfoTb4b4b4(Te6edf3num Tff7b72= T79c0ff9T79c0ff9T79c0ff9Tb4b4b4)Tb4b4b4)
Te6edf3verifyTb4b4b4(Te6edf3mode Tff7b72= Te6edf3VerifyModeTb4b4b4.Te6edf3notTb4b4b4) Tb4b4b4{ Te6edf3connectionManagerTb4b4b4.Te6edf3onHandshakeProgressTb4b4b4(Tb4b4b4) Tb4b4b4}
Tb4b4b4}
T8b949e/**
* Regression guard: a full handshake must fire [MeshConnectionManager.onHandshakeProgress] exactly for meaningful
* handshake events only. Packet types not meaningful to the handshake โ queueStatus, mqttClientProxyMessage,
* xmodemPacket, clientNotification, deviceuiConfig, and rebooted โ are routed to sibling handlers
* (PacketHandlerImpl, MqttManagerImpl, FromRadioPacketHandlerImpl, MeshConfigHandlerImpl) and must never reset the
* watchdog from this manager. This test pins the exact count so any accidental wiring surfaces as a failure.
*/
Tf0883e@Test
Tff7b72fun Td2a8ff`full handshake fires onHandshakeProgress exactly for meaningful events only`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3testNode Tff7b72= Te6edf3orgTb4b4b4.Te6edf3meshtasticTb4b4b4.Te6edf3coreTb4b4b4.Te6edf3testingTb4b4b4.Te6edf3TestDataFactoryTb4b4b4.Te6edf3createTestNodeTb4b4b4(Te6edf3num Tff7b72= T79c0ff1T79c0ff0T79c0ff0Tb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3nodeDBbyNodeNum Tb4b4b4} Te6edf3returns Te6edf3mapOfTb4b4b4(T79c0ff1T79c0ff0T79c0ff0 Te6edf3to Te6edf3testNodeTb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleMyInfoTb4b4b4(Te6edf3protoMyNodeInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleLocalMetadataTb4b4b4(Te6edf3metadataTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleConfigCompleteTb4b4b4(Te6edf3HandshakeConstantsTb4b4b4.Te6edf3CONFIG_NONCETb4b4b4)
Te6edf3advanceTimeByTb4b4b4(Te6edf3STAGE_TRANSITION_ADVANCE_MSTb4b4b4)
Te6edf3runCurrentTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleNodeInfoTb4b4b4(Te6edf3NodeInfoTb4b4b4(Te6edf3num Tff7b72= T79c0ff1T79c0ff0T79c0ff0Tb4b4b4)Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleConfigCompleteTb4b4b4(Te6edf3HandshakeConstantsTb4b4b4.Te6edf3NODE_INFO_NONCETb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
T8b949e// handleMyInfo(1) + handleLocalMetadata(1) + handleConfigOnlyComplete(1)
T8b949e// + handleNodeInfo(1) = 4. handleNodeInfoComplete intentionally does NOT call
T8b949e// onHandshakeProgress: by that point the handshake is Complete and the synchronous
T8b949e// onHandshakeComplete() call (verified in a separate test) cancels the watchdog.
Te6edf3verifyTb4b4b4(Te6edf3mode Tff7b72= Te6edf3VerifyModeTb4b4b4.Te6edf3exactlyTb4b4b4(T79c0ff4Tb4b4b4)Tb4b4b4) Tb4b4b4{ Te6edf3connectionManagerTb4b4b4.Te6edf3onHandshakeProgressTb4b4b4(Tb4b4b4) Tb4b4b4}
Tb4b4b4}
T8b949e/**
* Regression guard for the Stage 2 watchdog-cancellation race fixed by adding
* [MeshConnectionManager.onHandshakeComplete]. Stage 2 completion must synchronously fire the terminal callback
* exactly once so the transport-aware fast-recovery watchdog is cancelled before any async DB install work begins.
*/
Tf0883e@Test
Tff7b72fun Td2a8ff`Stage 2 complete fires onHandshakeComplete exactly once`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3testNode Tff7b72= Te6edf3orgTb4b4b4.Te6edf3meshtasticTb4b4b4.Te6edf3coreTb4b4b4.Te6edf3testingTb4b4b4.Te6edf3TestDataFactoryTb4b4b4.Te6edf3createTestNodeTb4b4b4(Te6edf3num Tff7b72= T79c0ff1T79c0ff0T79c0ff0Tb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3nodeDBbyNodeNum Tb4b4b4} Te6edf3returns Te6edf3mapOfTb4b4b4(T79c0ff1T79c0ff0T79c0ff0 Te6edf3to Te6edf3testNodeTb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleMyInfoTb4b4b4(Te6edf3protoMyNodeInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleLocalMetadataTb4b4b4(Te6edf3metadataTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleConfigCompleteTb4b4b4(Te6edf3HandshakeConstantsTb4b4b4.Te6edf3CONFIG_NONCETb4b4b4)
Te6edf3advanceTimeByTb4b4b4(Te6edf3STAGE_TRANSITION_ADVANCE_MSTb4b4b4)
Te6edf3runCurrentTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleNodeInfoTb4b4b4(Te6edf3NodeInfoTb4b4b4(Te6edf3num Tff7b72= T79c0ff1T79c0ff0T79c0ff0Tb4b4b4)Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleConfigCompleteTb4b4b4(Te6edf3HandshakeConstantsTb4b4b4.Te6edf3NODE_INFO_NONCETb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3verifyTb4b4b4(Te6edf3mode Tff7b72= Te6edf3VerifyModeTb4b4b4.Te6edf3exactlyTb4b4b4(T79c0ff1Tb4b4b4)Tb4b4b4) Tb4b4b4{ Te6edf3connectionManagerTb4b4b4.Te6edf3onHandshakeCompleteTb4b4b4(Tb4b4b4) Tb4b4b4}
Tb4b4b4}
T8b949e/**
* Regression guard for the actual Stage 2 watchdog-cancellation race: the synchronous
* [MeshConnectionManager.onHandshakeComplete] call MUST land before the asynchronous NodeDB install work begins, so
* that a slow Room commit on a large mesh cannot trip the 12 s fast-recovery timeout after the firmware handshake
* has already succeeded.
*
* Under [StandardTestDispatcher] the async DB install coroutine does not run until the test dispatcher is advanced,
* so we can assert the call ordering deterministically without any suspension trick on
* [NodeRepository.installConfig].
*/
Tf0883e@Test
Tff7b72fun Td2a8ff`Stage 2 complete cancels watchdog synchronously before async DB install work`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3testScopeTb4b4b4.Te6edf3runTest Tb4b4b4{
Tff7b72val Te6edf3testNode Tff7b72= Te6edf3orgTb4b4b4.Te6edf3meshtasticTb4b4b4.Te6edf3coreTb4b4b4.Te6edf3testingTb4b4b4.Te6edf3TestDataFactoryTb4b4b4.Te6edf3createTestNodeTb4b4b4(Te6edf3num Tff7b72= T79c0ff1T79c0ff0T79c0ff0Tb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3nodeDBbyNodeNum Tb4b4b4} Te6edf3returns Te6edf3mapOfTb4b4b4(T79c0ff1T79c0ff0T79c0ff0 Te6edf3to Te6edf3testNodeTb4b4b4)
T8b949e// Record the order in which the synchronous watchdog-cancellation callback and the
T8b949e// async DB install entry point are observed. The order is the invariant under test.
Tff7b72val Te6edf3callOrder Tff7b72= Te6edf3mutableListOfTff7b72<Tffa657StringTff7b72>Tb4b4b4(Tb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3connectionManagerTb4b4b4.Te6edf3onHandshakeCompleteTb4b4b4(Tb4b4b4) Tb4b4b4} Te6edf3calls Tb4b4b4{ Te6edf3callOrderTb4b4b4.Te6edf3addTb4b4b4(Ta5d6ff"Ta5d6ffhandshakeCompleteTa5d6ff"Tb4b4b4) Tb4b4b4}
Te6edf3everySuspend Tb4b4b4{ Te6edf3nodeRepositoryTb4b4b4.Te6edf3installConfigTb4b4b4(Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4} Te6edf3calls Tb4b4b4{ Te6edf3callOrderTb4b4b4.Te6edf3addTb4b4b4(Ta5d6ff"Ta5d6ffinstallConfigTa5d6ff"Tb4b4b4) Tb4b4b4}
Te6edf3managerTb4b4b4.Te6edf3handleMyInfoTb4b4b4(Te6edf3protoMyNodeInfoTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleLocalMetadataTb4b4b4(Te6edf3metadataTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleConfigCompleteTb4b4b4(Te6edf3HandshakeConstantsTb4b4b4.Te6edf3CONFIG_NONCETb4b4b4)
Te6edf3advanceTimeByTb4b4b4(Te6edf3STAGE_TRANSITION_ADVANCE_MSTb4b4b4)
Te6edf3runCurrentTb4b4b4(Tb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3handleNodeInfoTb4b4b4(Te6edf3NodeInfoTb4b4b4(Te6edf3num Tff7b72= T79c0ff1T79c0ff0T79c0ff0Tb4b4b4)Tb4b4b4)
T8b949e// Drive Stage 2 complete. handleNodeInfoComplete runs synchronously: state becomes
T8b949e// Complete, onHandshakeComplete() fires (cancelling the watchdog), then the async DB
T8b949e// install block is launched but not yet executed under StandardTestDispatcher.
Te6edf3managerTb4b4b4.Te6edf3handleConfigCompleteTb4b4b4(Te6edf3HandshakeConstantsTb4b4b4.Te6edf3NODE_INFO_NONCETb4b4b4)
T8b949e// Synchronous post-condition: the watchdog was cancelled BEFORE the async DB install
T8b949e// block was scheduled to run. If this ordering invariant ever regresses, a slow Room
T8b949e// commit on a large mesh would falsely trip the 12s fast-recovery timeout.
Te6edf3assertEqualsTb4b4b4(
Te6edf3listOfTb4b4b4(Ta5d6ff"Ta5d6ffhandshakeCompleteTa5d6ff"Tb4b4b4)Tb4b4b4,
Te6edf3callOrderTb4b4b4,
Ta5d6ff"Ta5d6ffonHandshakeComplete() must fire synchronously at Stage 2 complete, BEFORE any Ta5d6ff" Tff7b72+
Ta5d6ff"Ta5d6ffasync DB install work begins โ this is the race this test guards againstTa5d6ff"Tb4b4b4,
Tb4b4b4)
T8b949e// Now let the async DB install block run.
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3assertEqualsTb4b4b4(
Te6edf3listOfTb4b4b4(Ta5d6ff"Ta5d6ffhandshakeCompleteTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffinstallConfigTa5d6ff"Tb4b4b4)Tb4b4b4,
Te6edf3callOrderTb4b4b4,
Ta5d6ff"Ta5d6ffinstallConfig must run AFTER onHandshakeComplete, ensuring the watchdog is Ta5d6ff" Tff7b72+
Ta5d6ff"Ta5d6ffalready cancelled before any DB work could trip the fast-recovery timeoutTa5d6ff"Tb4b4b4,
Tb4b4b4)
Tb4b4b4}
Tb4b4b4}
Served by rngit 1.5.0 - Generated in 0.16s